package com.sts.sink.model;

import com.sts.sink.StsSink;
import com.sts.source.StsSource;
import com.sts.task.StsTask;
import lombok.Getter;
import lombok.Setter;

@Getter
@Setter
public abstract class BaseSinkConfig {

    private int threadCount = 1;
    private int batchSize = 1000;

    private boolean hasHeader = true;

    public abstract StsSink buildImpl(StsSource stsSource, StsTask stsTask);
}
